package com.lianjia.sh.se;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.concurrent.ExecutionException;

/**
 * Created by yangsp1 on 16/8/31.
 */
@Configuration
public class ConfigTest {
    @Autowired
    MyKafkaSender myKafkaSender;
    @Bean
    public Object aa(){
        try {
            myKafkaSender.send("aaa");
        } catch (ExecutionException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return new Object();
    }
}
